package concurrentwrite.callback.run;

import java.io.File;
import java.util.Arrays;
import java.util.List;
import java.util.PriorityQueue;
import java.util.concurrent.ConcurrentLinkedQueue;

/**
 * Created by IntelliJ IDEA.
 * User: tuyuri
 * Date: 01/06/2012
 * Time: 00:15
 * To change this template use File | Settings | File Templates.
 */
public class DataQueue {
    public static PriorityQueue<String> dataFilesQueue;
    public static int MAX_ROWS_A_BATCH;
    public static int NUMBER_THREAD_IN_WRAP_POOL;
    public static int NUMBER_THREAD_IN_MUTATE_POOL;
    //    public static String folderPath = "f:\\logs2";
//    public static String folderPath = "/home/bigdata/test";
//    public static String folderPath = "/home/bigdata/test";
    public static String folderPath = "/home/bigdata/log3";
//    public static String folderPath = "/home/bigdata/data/2012-05-24";


    public static void init() {
        File dir = new File(folderPath);
        String[] lstFiles = dir.list();
        List<String> filesNameList = Arrays.asList(lstFiles);
        dataFilesQueue = new PriorityQueue<String>(filesNameList);
    }
}
